sergey-telpuk / nestjs-transport-eventbus

@CommandHandler(TryAggregateRootCommand)

export class TryAggregateRootCommandHandler implements ICommandHandler<TryAggregateRootCommand> {

    constructor(

        @Inject(TRANSPORT_EVENT_BUS_PUBLISHER) private readonly publisher: EventPublisher

    ) {

    }

    async execute(command: TryAggregateRootCommand) {

        const {message} = command;

        const aggregator = this.publisher.mergeObjectContext(

            new TestModel()

        );

        aggregator.applyEvent(message);

        aggregator.commit();